package _04_Stream;

import java.util.Arrays;
import java.util.List;
import java.util.stream.IntStream;
import java.util.stream.Stream;

public class _01_Stream {

	public static void main(String[] args) {
		// 1.通过数组 Stream.of
		// Stream 类中的静态方法
		String[] strings = { "q", "w", "e", "r", "d", "f" };
		Stream<String> stream1 = Stream.of(strings);
		Stream<String> stream3 = Arrays.stream(strings);

		// 2.通过集合
		// 集合提供的 stream()方法或parallelStream()
		List<String> string2 = Arrays.asList(strings);
		Stream<String> stream2 = string2.stream();

		// 3.通过 Stream.generate 方法创建
		// 这是一个无限流(无限大),通过这种方式创建的流,在操作的时候,最好使用 limit 进行最大数量限制

		// generate 的参数是 Supplier,只有一个 get 方法,是无参有返回值的,所以 ()->xxxx
		Stream<Integer> generate = Stream.generate(() -> 111);
		// 通过 limit 限制最多元素个数为 3 个
		generate.limit(3).forEach(x -> System.out.println(x));

		System.out.println("1111");

		// 4.通过Stream.iterate 方法来创建
		// 这是一个有序无限流(无限大),通过这种方式创建的流,在操作的时候,最好使用 limit 进行最大数量限制

		// iterate() 第一个是起始值,第二个参数是 UnaryOperator,继承了 Function ,所以是有参有返回值
		// 1 表示起始值,x+2等于是步长,就类似于一个死循环,起始值是1,步长是2
		Stream<Integer> iterate = Stream.iterate(1, x -> x + 2);
		// 通过 limit 限制最多元素个数为 10 个
		iterate.limit(10).forEach(x -> System.out.println(x));

		// 5.已有类的 Stream 源生成 API
		String str = "abc";
		IntStream chars = str.chars();
		// 97,98,99
		chars.forEach(x -> System.out.println(x));
	}

}
